package com.eastfair.datasync.listener;

import com.eastfair.datasync.entity.CanalData;

public interface SyncInterface<T> {
    /**
     * 添加操作
     * @param canalData
     */
    void executeInsert(CanalData canalData);
    /**
     * 更新操作
     * @param canalData
     */
    void executeUpdate(CanalData canalData);
    /**
     * 添加字段操作
     * @param canalData
     */
    void executeAlter(CanalData canalData);


    /**
     * 整体执行
     * @param message
     * @param c
     */
    void executeAll(String message,T t);
}
